package com.laogao.lesson005;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;

public class SemaphoreExample {

    // 定义一个Semaphore，初始许可数为3
    private static final Semaphore semaphore = new Semaphore(3);

    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executor = Executors.newFixedThreadPool(5);

        // 模拟5个线程尝试访问一个只允许3个并发访问的资源
        for (int i = 0; i < 5; i++) {
            final int threadId = i;
            executor.execute(() -> {
                try {
                    // 获取一个许可
                    semaphore.acquire();
                    accessResource(threadId);
                    // 访问完成后释放许可
                    semaphore.release();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
        }

        // 关闭线程池（这在实际应用中通常会在所有任务完成后进行）
        // executor.shutdown();
    }

    // 模拟访问资源的方法
    private static void accessResource(int threadId) throws InterruptedException {
        System.out.println("线程 " + threadId + " 获取到许可，开始访问资源。");
        // 模拟资源访问时间
        Thread.sleep(1000);
        System.out.println("线程 " + threadId + " 访问资源结束，释放许可。");
    }
}